package com.klm.easymq.core.impl;

import com.klm.easymq.core.MessageSerializer;
import lombok.extern.slf4j.Slf4j;

/**
 * Protobuf消息序列化器实现
 * 预留实现，后续可以扩展
 */
@Slf4j
public class ProtobufMessageSerializer implements MessageSerializer {
    
    @Override
    public byte[] serialize(Object message) {
        // TODO: 实现Protobuf序列化
        log.warn("Protobuf序列化器尚未实现，返回消息的toString()字节数组");
        return message != null ? message.toString().getBytes() : new byte[0];
    }
    
    @Override
    public <T> T deserialize(byte[] data, Class<T> clazz) {
        // TODO: 实现Protobuf反序列化
        log.warn("Protobuf反序列化器尚未实现，返回null");
        return null;
    }
    
    @Override
    public String getType() {
        return "protobuf";
    }
} 